{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "import yaml\n",
    "import pandas as pd\n",
    "from sqlalchemy import create_engine as cg\n",
    "\n",
    "\n",
    "def load_config():\n",
    "    with open(\"config.yaml\", 'r', encoding='utf-8') as f:\n",
    "        data = yaml.load(f.read(), Loader=yaml.FullLoader)\n",
    "    return data\n",
    "\n",
    "\n",
    "def get_tjd_engine(config):\n",
    "    mysql_args = config['mysql']\n",
    "    user = mysql_args['user']\n",
    "    ip = mysql_args['ip']\n",
    "    data_base = mysql_args['database']\n",
    "    password = mysql_args['password']\n",
    "    engine = cg(f'mysql+pymysql://{user}:{password}@{ip}:3306/{data_base}?charset=utf8')\n",
    "    return engine"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取配置参数"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "dict_keys(['mysql', 'pages', 'trade_date', 'exchange', 'tjd_category'])"
      ]
     },
     "execution_count": 5,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "config = load_config()\n",
    "config.keys()"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取交易所"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 6,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "dict_keys(['SHFE', 'DCE', 'CZC', 'INE', 'CFFEX'])"
      ]
     },
     "execution_count": 6,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "exchange = config['exchange'].keys()\n",
    "exchange"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取每个交易所的交易品种"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 11,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "交易所 SHFE  期货品种  螺纹钢\n",
      "交易所 SHFE  期货品种  热轧卷板\n",
      "交易所 SHFE  期货品种  不锈钢\n",
      "交易所 SHFE  期货品种  沪铜\n",
      "交易所 SHFE  期货品种  沪锌\n",
      "交易所 SHFE  期货品种  沪镍\n",
      "交易所 SHFE  期货品种  沪铝\n",
      "交易所 SHFE  期货品种  沪铅\n",
      "交易所 SHFE  期货品种  沪锡\n",
      "交易所 SHFE  期货品种  橡胶\n",
      "交易所 SHFE  期货品种  SHFE黄金\n",
      "交易所 SHFE  期货品种  沪银\n",
      "交易所 SHFE  期货品种  沥青\n",
      "交易所 DCE  期货品种  焦煤\n",
      "交易所 DCE  期货品种  焦炭\n",
      "交易所 DCE  期货品种  铁矿石\n",
      "交易所 DCE  期货品种  LPG\n",
      "交易所 DCE  期货品种  聚丙烯\n",
      "交易所 DCE  期货品种  PVC\n",
      "交易所 DCE  期货品种  塑料\n",
      "交易所 DCE  期货品种  苯乙烯\n",
      "交易所 DCE  期货品种  豆一\n",
      "交易所 DCE  期货品种  豆二\n",
      "交易所 DCE  期货品种  豆粕\n",
      "交易所 DCE  期货品种  豆油\n",
      "交易所 DCE  期货品种  棕榈油\n",
      "交易所 DCE  期货品种  玉米\n",
      "交易所 DCE  期货品种  生猪\n",
      "交易所 DCE  期货品种  鲜鸡蛋\n",
      "交易所 CZC  期货品种  动力煤\n",
      "交易所 CZC  期货品种  苹果\n",
      "交易所 CZC  期货品种  锰硅\n",
      "交易所 CZC  期货品种  硅铁\n",
      "交易所 CZC  期货品种  玻璃\n",
      "交易所 CZC  期货品种  纯碱\n",
      "交易所 CZC  期货品种  甲醇\n",
      "交易所 CZC  期货品种  尿素\n",
      "交易所 CZC  期货品种  短纤\n",
      "交易所 CZC  期货品种  PTA\n",
      "交易所 CZC  期货品种  棉花\n",
      "交易所 CZC  期货品种  棉纱\n",
      "交易所 CZC  期货品种  菜粕\n",
      "交易所 CZC  期货品种  菜油\n",
      "交易所 CZC  期货品种  油菜籽\n",
      "交易所 CZC  期货品种  红枣\n",
      "交易所 CZC  期货品种  白糖\n",
      "交易所 INE  期货品种  原油\n",
      "交易所 CFFEX  期货品种  沪深300\n",
      "交易所 CFFEX  期货品种  上证50\n",
      "交易所 CFFEX  期货品种  中证500\n",
      "交易所 CFFEX  期货品种  10年期国债期货\n",
      "交易所 CFFEX  期货品种  5年期国债期货\n",
      "交易所 CFFEX  期货品种  2年期国债期货\n"
     ]
    }
   ],
   "source": [
    "for k, v in config['exchange'].items():\n",
    "    for character_name in list(v.keys()):\n",
    "        print(f\"交易所 {k}  期货品种  {character_name}\")"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取mysql引擎"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 12,
   "metadata": {},
   "outputs": [],
   "source": [
    "my_engine = get_tjd_engine(config=config)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取腾景分类期货数据一级指标和所属关系（字典）"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 15,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "dict_keys(['钢铁', '能化', '有色', '农产品', '非金属建材'])"
      ]
     },
     "execution_count": 15,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "tjd_l1 = config['tjd_category']\n",
    "tjd_l1.keys()"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取一级分类包含品种中文名"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 14,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "L1: 钢铁 包含 L2: ['螺纹钢', '热轧卷板', '焦煤', '焦炭', '铁矿石', '硅铁', '锰硅', '不锈钢']\n",
      "L1: 能化 包含 L2: ['原油', '甲醇', '沥青', '动力煤', '橡胶']\n",
      "L1: 有色 包含 L2: ['沪铜', '沪铝', '沪铅', '沪锌', '沪镍']\n",
      "L1: 农产品 包含 L2: ['生猪', '豆一', '苹果', '豆粕', '豆油', '菜粕', '菜油', '红枣', '棕榈油', '棉花', '棉纱', '白糖']\n",
      "L1: 非金属建材 包含 L2: ['玻璃', '纯碱', 'PVC']\n"
     ]
    }
   ],
   "source": [
    "for l1_name, l2_li in tjd_l1.items():\n",
    "    print(\"L1:\", l1_name, \"包含 L2:\", l2_li)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 获取所有品种"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 16,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "{'螺纹钢': ['RB.SHF', 'rb_shf'],\n",
       " '热轧卷板': ['HC.SHF', 'hc_shf'],\n",
       " '不锈钢': ['SS.SHF', 'ss_shf'],\n",
       " '沪铜': ['CU.SHF', 'cu_shf'],\n",
       " '沪锌': ['ZN.SHF', 'zn_shf'],\n",
       " '沪镍': ['NI.SHF', 'ni_shf'],\n",
       " '沪铝': ['AL.SHF', 'al_shf'],\n",
       " '沪铅': ['PB.SHF', 'pb_shf'],\n",
       " '沪锡': ['SN.SHF', 'sn_shf'],\n",
       " '橡胶': ['RU.SHF', 'ru_shf'],\n",
       " 'SHFE黄金': ['AU.SHF', 'au_shf'],\n",
       " '沪银': ['AG.SHF', 'ag_shf'],\n",
       " '沥青': ['BU.SHF', 'bu_shf'],\n",
       " '焦煤': ['JM.DCE', 'jm_dce'],\n",
       " '焦炭': ['J.DCE', 'j_dce'],\n",
       " '铁矿石': ['I.DCE', 'i_dce'],\n",
       " 'LPG': ['PG.DCE', 'pg_dce'],\n",
       " '聚丙烯': ['PP.DCE', 'pp_dce'],\n",
       " 'PVC': ['PVC.DCE', 'v_dce'],\n",
       " '塑料': ['L.DCE', 'l_dce'],\n",
       " '苯乙烯': ['EB.DCE', 'eb_dce'],\n",
       " '豆一': ['A.DCE', 'a_dce'],\n",
       " '豆二': ['B.DCE', 'b_dce'],\n",
       " '豆粕': ['M.DCE', 'm_dce'],\n",
       " '豆油': ['Y.DCE', 'y_dce'],\n",
       " '棕榈油': ['P.DCE', 'p_dce'],\n",
       " '玉米': ['C.DCE', 'c_dce'],\n",
       " '生猪': ['LH.DCE', 'lh_dce'],\n",
       " '鲜鸡蛋': ['JD.DCE', 'jd_dce'],\n",
       " '动力煤': ['ZC.CZC', 'zc_zce'],\n",
       " '苹果': ['AP.CZC', 'ap_zce'],\n",
       " '锰硅': ['SM.CZC', 'sm_zce'],\n",
       " '硅铁': ['SF.CZC', 'sf_zce'],\n",
       " '玻璃': ['FG.CZC', 'fg_zce'],\n",
       " '纯碱': ['SA.CZC', 'sa_zce'],\n",
       " '甲醇': ['MA.CZC', 'ma_zce'],\n",
       " '尿素': ['UR.CZC', 'ur_zce'],\n",
       " '短纤': ['PF.CZC', 'pf_zce'],\n",
       " 'PTA': ['TA.CZC', 'ta_zce'],\n",
       " '棉花': ['CF.CZC', 'cf_zce'],\n",
       " '棉纱': ['CY.CZC', 'cy_zce'],\n",
       " '菜粕': ['RM.CZC', 'rm_zce'],\n",
       " '菜油': ['OI.CZC', 'oi_zce'],\n",
       " '油菜籽': ['RS.CZC', 'rs_zce'],\n",
       " '红枣': ['CJ.CZC', 'cj_zce'],\n",
       " '白糖': ['SR.CZC', 'sr_zce'],\n",
       " '原油': ['SC.INE', 'sc_ine'],\n",
       " '沪深300': ['IF.CFE', 'if_cfx'],\n",
       " '上证50': ['IH.CFE', 'ih_cfx'],\n",
       " '中证500': ['IC.CFE', 'ic_cfx'],\n",
       " '10年期国债期货': ['T.CFE', 't_cfx'],\n",
       " '5年期国债期货': ['TF.CFE', 'tf_cfx'],\n",
       " '2年期国债期货': ['TS.CFE', 'ts_cfx']}"
      ]
     },
     "execution_count": 16,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "all_category = {}\n",
    "for exchange, exchange_codes in config['exchange'].items():\n",
    "    all_category = {**all_category, **exchange_codes}\n",
    "all_category"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 依次从数据库中遍历数据"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 23,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "中文名称  螺纹钢               future_codeRB.SHF    mysql 表名字      rb_shf   shape:(2231, 15)\n",
      "中文名称  热轧卷板             future_codeHC.SHF    mysql 表名字      hc_shf   shape:(1887, 15)\n",
      "中文名称  不锈钢               future_codeSS.SHF    mysql 表名字      ss_shf   shape:(539, 15)\n",
      "中文名称  沪铜                 future_codeCU.SHF    mysql 表名字      cu_shf   shape:(2231, 15)\n",
      "中文名称  沪锌                 future_codeZN.SHF    mysql 表名字      zn_shf   shape:(2231, 15)\n",
      "中文名称  沪镍                 future_codeNI.SHF    mysql 表名字      ni_shf   shape:(1639, 15)\n",
      "中文名称  沪铝                 future_codeAL.SHF    mysql 表名字      al_shf   shape:(2231, 15)\n",
      "中文名称  沪铅                 future_codePB.SHF    mysql 表名字      pb_shf   shape:(2231, 15)\n",
      "中文名称  沪锡                 future_codeSN.SHF    mysql 表名字      sn_shf   shape:(1639, 15)\n",
      "中文名称  橡胶                 future_codeRU.SHF    mysql 表名字      ru_shf   shape:(2231, 15)\n",
      "中文名称  SHFE黄金         future_codeAU.SHF    mysql 表名字      au_shf   shape:(2231, 15)\n",
      "中文名称  沪银                 future_codeAG.SHF    mysql 表名字      ag_shf   shape:(2231, 15)\n",
      "中文名称  沥青                 future_codeBU.SHF    mysql 表名字      bu_shf   shape:(1998, 15)\n",
      "中文名称  焦煤                 future_codeJM.DCE    mysql 表名字      jm_dce   shape:(2126, 15)\n",
      "中文名称  焦炭                 future_codeJ.DCE    mysql 表名字      j_dce   shape:(2231, 15)\n",
      "中文名称  铁矿石               future_codeI.DCE    mysql 表名字      i_dce   shape:(1991, 15)\n",
      "中文名称  LPG               future_codePG.DCE    mysql 表名字      pg_dce   shape:(418, 15)\n",
      "中文名称  聚丙烯               future_codePP.DCE    mysql 表名字      pp_dce   shape:(1902, 15)\n",
      "中文名称  PVC               future_codePVC.DCE    mysql 表名字      v_dce   shape:(2231, 15)\n",
      "中文名称  塑料                 future_codeL.DCE    mysql 表名字      l_dce   shape:(2231, 15)\n",
      "中文名称  苯乙烯               future_codeEB.DCE    mysql 表名字      eb_dce   shape:(538, 15)\n",
      "中文名称  豆一                 future_codeA.DCE    mysql 表名字      a_dce   shape:(2231, 15)\n",
      "中文名称  豆二                 future_codeB.DCE    mysql 表名字      b_dce   shape:(2231, 15)\n",
      "中文名称  豆粕                 future_codeM.DCE    mysql 表名字      m_dce   shape:(2231, 15)\n",
      "中文名称  豆油                 future_codeY.DCE    mysql 表名字      y_dce   shape:(2231, 15)\n",
      "中文名称  棕榈油               future_codeP.DCE    mysql 表名字      p_dce   shape:(2231, 15)\n",
      "中文名称  玉米                 future_codeC.DCE    mysql 表名字      c_dce   shape:(2231, 15)\n",
      "中文名称  生猪                 future_codeLH.DCE    mysql 表名字      lh_dce   shape:(227, 15)\n",
      "中文名称  鲜鸡蛋               future_codeJD.DCE    mysql 表名字      jd_dce   shape:(1976, 15)\n",
      "中文名称  动力煤               future_codeZC.CZC    mysql 表名字      zc_zce   shape:(2002, 15)\n",
      "中文名称  苹果                 future_codeAP.CZC    mysql 表名字      ap_zce   shape:(967, 15)\n",
      "中文名称  锰硅                 future_codeSM.CZC    mysql 表名字      sm_zce   shape:(1791, 15)\n",
      "中文名称  硅铁                 future_codeSF.CZC    mysql 表名字      sf_zce   shape:(1791, 15)\n",
      "中文名称  玻璃                 future_codeFG.CZC    mysql 表名字      fg_zce   shape:(2197, 15)\n",
      "中文名称  纯碱                 future_codeSA.CZC    mysql 表名字      sa_zce   shape:(492, 15)\n",
      "中文名称  甲醇                 future_codeMA.CZC    mysql 表名字      ma_zce   shape:(2231, 15)\n",
      "中文名称  尿素                 future_codeUR.CZC    mysql 表名字      ur_zce   shape:(571, 15)\n",
      "中文名称  短纤                 future_codePF.CZC    mysql 表名字      pf_zce   shape:(290, 15)\n",
      "中文名称  PTA               future_codeTA.CZC    mysql 表名字      ta_zce   shape:(2231, 15)\n",
      "中文名称  棉花                 future_codeCF.CZC    mysql 表名字      cf_zce   shape:(2231, 15)\n",
      "中文名称  棉纱                 future_codeCY.CZC    mysql 表名字      cy_zce   shape:(1052, 15)\n",
      "中文名称  菜粕                 future_codeRM.CZC    mysql 表名字      rm_zce   shape:(2178, 15)\n",
      "中文名称  菜油                 future_codeOI.CZC    mysql 表名字      oi_zce   shape:(2231, 15)\n",
      "中文名称  油菜籽               future_codeRS.CZC    mysql 表名字      rs_zce   shape:(2036, 15)\n",
      "中文名称  红枣                 future_codeCJ.CZC    mysql 表名字      cj_zce   shape:(640, 15)\n",
      "中文名称  白糖                 future_codeSR.CZC    mysql 表名字      sr_zce   shape:(2231, 15)\n",
      "中文名称  原油                 future_codeSC.INE    mysql 表名字      sc_ine   shape:(907, 15)\n",
      "中文名称  沪深300           future_codeIF.CFE    mysql 表名字      if_cfx   shape:(2231, 15)\n",
      "中文名称  上证50             future_codeIH.CFE    mysql 表名字      ih_cfx   shape:(1626, 15)\n",
      "中文名称  中证500           future_codeIC.CFE    mysql 表名字      ic_cfx   shape:(1626, 15)\n",
      "中文名称  10年期国债期货     future_codeT.CFE    mysql 表名字      t_cfx   shape:(1644, 15)\n",
      "中文名称  5年期国债期货       future_codeTF.CFE    mysql 表名字      tf_cfx   shape:(2014, 15)\n",
      "中文名称  2年期国债期货       future_codeTS.CFE    mysql 表名字      ts_cfx   shape:(808, 15)\n"
     ]
    }
   ],
   "source": [
    "for character_name, future_code in all_category.items():\n",
    "    data = pd.read_sql(f\"select * from {future_code[1]}\", my_engine)\n",
    "    sss = \"  \" * (10-len(character_name))\n",
    "    print(f\"中文名称  {character_name}{sss} future_code{future_code[0]}    mysql 表名字      {future_code[1]}   shape:{data.shape}\")"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# 根据腾景二级分类获取日度K线数据"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 27,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "腾景分类 l1行业钢铁 中文名称   螺纹钢 wind_code  RB.SHF  mysql表名 rb_shf data shape (2231, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   热轧卷板 wind_code  HC.SHF  mysql表名 hc_shf data shape (1887, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   焦煤 wind_code  JM.DCE  mysql表名 jm_dce data shape (2126, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   焦炭 wind_code  J.DCE  mysql表名 j_dce data shape (2231, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   铁矿石 wind_code  I.DCE  mysql表名 i_dce data shape (1991, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   硅铁 wind_code  SF.CZC  mysql表名 sf_zce data shape (1791, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   锰硅 wind_code  SM.CZC  mysql表名 sm_zce data shape (1791, 15)\n",
      "腾景分类 l1行业钢铁 中文名称   不锈钢 wind_code  SS.SHF  mysql表名 ss_shf data shape (539, 15)\n",
      "腾景分类 l1行业能化 中文名称   原油 wind_code  SC.INE  mysql表名 sc_ine data shape (907, 15)\n",
      "腾景分类 l1行业能化 中文名称   甲醇 wind_code  MA.CZC  mysql表名 ma_zce data shape (2231, 15)\n",
      "腾景分类 l1行业能化 中文名称   沥青 wind_code  BU.SHF  mysql表名 bu_shf data shape (1998, 15)\n",
      "腾景分类 l1行业能化 中文名称   动力煤 wind_code  ZC.CZC  mysql表名 zc_zce data shape (2002, 15)\n",
      "腾景分类 l1行业能化 中文名称   橡胶 wind_code  RU.SHF  mysql表名 ru_shf data shape (2231, 15)\n",
      "腾景分类 l1行业有色 中文名称   沪铜 wind_code  CU.SHF  mysql表名 cu_shf data shape (2231, 15)\n",
      "腾景分类 l1行业有色 中文名称   沪铝 wind_code  AL.SHF  mysql表名 al_shf data shape (2231, 15)\n",
      "腾景分类 l1行业有色 中文名称   沪铅 wind_code  PB.SHF  mysql表名 pb_shf data shape (2231, 15)\n",
      "腾景分类 l1行业有色 中文名称   沪锌 wind_code  ZN.SHF  mysql表名 zn_shf data shape (2231, 15)\n",
      "腾景分类 l1行业有色 中文名称   沪镍 wind_code  NI.SHF  mysql表名 ni_shf data shape (1639, 15)\n",
      "腾景分类 l1行业农产品 中文名称   生猪 wind_code  LH.DCE  mysql表名 lh_dce data shape (227, 15)\n",
      "腾景分类 l1行业农产品 中文名称   豆一 wind_code  A.DCE  mysql表名 a_dce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   苹果 wind_code  AP.CZC  mysql表名 ap_zce data shape (967, 15)\n",
      "腾景分类 l1行业农产品 中文名称   豆粕 wind_code  M.DCE  mysql表名 m_dce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   豆油 wind_code  Y.DCE  mysql表名 y_dce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   菜粕 wind_code  RM.CZC  mysql表名 rm_zce data shape (2178, 15)\n",
      "腾景分类 l1行业农产品 中文名称   菜油 wind_code  OI.CZC  mysql表名 oi_zce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   红枣 wind_code  CJ.CZC  mysql表名 cj_zce data shape (640, 15)\n",
      "腾景分类 l1行业农产品 中文名称   棕榈油 wind_code  P.DCE  mysql表名 p_dce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   棉花 wind_code  CF.CZC  mysql表名 cf_zce data shape (2231, 15)\n",
      "腾景分类 l1行业农产品 中文名称   棉纱 wind_code  CY.CZC  mysql表名 cy_zce data shape (1052, 15)\n",
      "腾景分类 l1行业农产品 中文名称   白糖 wind_code  SR.CZC  mysql表名 sr_zce data shape (2231, 15)\n",
      "腾景分类 l1行业非金属建材 中文名称   玻璃 wind_code  FG.CZC  mysql表名 fg_zce data shape (2197, 15)\n",
      "腾景分类 l1行业非金属建材 中文名称   纯碱 wind_code  SA.CZC  mysql表名 sa_zce data shape (492, 15)\n",
      "腾景分类 l1行业非金属建材 中文名称   PVC wind_code  PVC.DCE  mysql表名 v_dce data shape (2231, 15)\n"
     ]
    }
   ],
   "source": [
    "for l1_name, l2_li in tjd_l1.items():\n",
    "    for l2_name in l2_li:\n",
    "        future_code = all_category[l2_name]\n",
    "        data = pd.read_sql(f\"select * from {future_code[1]}\", my_engine)\n",
    "        print(f\"腾景分类 l1行业{l1_name} 中文名称   {l2_name} wind_code  {future_code[0]}  mysql表名 {future_code[1]} data shape {data.shape}\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.8.5"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}
